package drds.data_propagate.parse.binlog_position;

import drds.data_propagate.common.LifeCycle;
import drds.data_propagate.parse.exception.ParseException;
import drds.propagate.protocol.position.LogPosition;

/**
 * Created by yinxiu on 17/3/17. Email: marklin.hz@gmail.com
 */
public interface LogPositionManager extends LifeCycle {

    LogPosition getLatestIndexBy(String destination);

    void persistLogPosition(String destination, LogPosition logPosition) throws ParseException;

}
